package com.example.listener;

import com.example.annotation.MQListener;
import com.example.constant.MQConstant;
import com.example.message.MqMessageReturn;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@MQListener(name = "xxxx.topic.listener", type = MQConstant.TOPIC)
public class SysMQTopicTestListener implements SysMQMessageListener {

    Logger logger = LoggerFactory.getLogger(getClass());

    @Override
    public MqMessageReturn onMessage(String message) throws Exception {
        logger.warn("SysMQTopicTestListener 收到消息: " + message);
        return MqMessageReturn.success();
    }
}
